All files / src/app/api/sort-results/[id]/shares route.ts

91.3% Statements 21/23
75% Branches 6/8
100% Functions 2/2
95% Lines 19/20

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47                        2x 2x 2x 2x 2x 2x 1x 1x                   3x 3x 3x 3x     3x 3x 2x   1x 1x 1x   1x      
import { NextRequest, NextResponse } from "next/server";
import { requireAuth } from "@/lib/auth";
import { CreateShareSchema, ShareController } from "@/server/api/shares";
import { SortResultService } from "@/server/services/SortResultService";
import { getDb } from "@/lib/db";
import { requireApiResultAccess } from "@/server/dal/collection-access";
import { errorResponse } from "@/server/api/http-errors";
 
export async function GET(
  _request: NextRequest,
  { params }: { params: Promise<{ id: string }> }
) {
  try {
    const { id } = await params;
    const user = await requireAuth();
    const db = getDb();
    const access = await requireApiResultAccess(db, id, user.id);
    if (access instanceof NextResponse) return access;
    const shares = await ShareController.fromDb(db).listShares(id);
    return NextResponse.json(shares);
  } catch (error) {
    return errorResponse(error);
  }
}
 
export async function POST(
  request: NextRequest,
  { params }: { params: Promise<{ id: string }> }
) {
  try {
    const { id } = await params;
    const user = await requireAuth();
    const db = getDb();
    // Authz BEFORE body parse: an unauthorized caller must get 403/404, never a
    // body-shape 400 that leaks the result's existence (ยง3.4 oracle posture).
    const access = await requireApiResultAccess(db, id, user.id);
    if (access instanceof NextResponse) return access;
    const { expiresAt } = CreateShareSchema.parse(await request.json());
    // Under the curator lock (purses-w7ss.18): never between a deletion's shares and results deletes.
    const share = await SortResultService.fromDb(db).createShare(id, expiresAt ? new Date(expiresAt) : undefined);
    Iif (!share) return NextResponse.json({ error: "Not found" }, { status: 404 });
    return NextResponse.json(share, { status: 201 });
  } catch (error) {
    return errorResponse(error);
  }
}